google.golang.org/grpc/internal/balancer/gracefulswitch.balancerWrapper.gsb (field)

30 uses

	google.golang.org/grpc/internal/balancer/gracefulswitch (current package)
		gracefulswitch.go#L120: 		gsb:        gsb,
		gracefulswitch.go#L298: 	gsb     *Balancer
		gracefulswitch.go#L319: 	bw.gsb.mu.Lock()
		gracefulswitch.go#L323: 	bw.gsb.mu.Unlock()
		gracefulswitch.go#L330: 	bw.gsb.mu.Lock()
		gracefulswitch.go#L331: 	defer bw.gsb.mu.Unlock()
		gracefulswitch.go#L337: 	if !bw.gsb.balancerCurrentOrPending(bw) {
		gracefulswitch.go#L343: 	if bw == bw.gsb.balancerCurrent {
		gracefulswitch.go#L349: 		if state.ConnectivityState != connectivity.Ready && bw.gsb.balancerPending != nil {
		gracefulswitch.go#L350: 			bw.gsb.swap()
		gracefulswitch.go#L359: 		bw.gsb.cc.UpdateState(state)
		gracefulswitch.go#L367: 	if state.ConnectivityState != connectivity.Connecting || bw.gsb.balancerCurrent.lastState.ConnectivityState != connectivity.Ready {
		gracefulswitch.go#L368: 		bw.gsb.swap()
		gracefulswitch.go#L373: 	bw.gsb.mu.Lock()
		gracefulswitch.go#L374: 	if !bw.gsb.balancerCurrentOrPending(bw) {
		gracefulswitch.go#L375: 		bw.gsb.mu.Unlock()
		gracefulswitch.go#L378: 	bw.gsb.mu.Unlock()
		gracefulswitch.go#L382: 	opts.StateListener = func(state balancer.SubConnState) { bw.gsb.updateSubConnState(sc, state, oldListener) }
		gracefulswitch.go#L383: 	sc, err := bw.gsb.cc.NewSubConn(addrs, opts)
		gracefulswitch.go#L387: 	bw.gsb.mu.Lock()
		gracefulswitch.go#L388: 	if !bw.gsb.balancerCurrentOrPending(bw) { // balancer was closed during this call
		gracefulswitch.go#L390: 		bw.gsb.mu.Unlock()
		gracefulswitch.go#L394: 	bw.gsb.mu.Unlock()
		gracefulswitch.go#L401: 	if bw != bw.gsb.latestBalancer() {
		gracefulswitch.go#L404: 	bw.gsb.cc.ResolveNow(opts)
		gracefulswitch.go#L414: 	bw.gsb.mu.Lock()
		gracefulswitch.go#L415: 	if !bw.gsb.balancerCurrentOrPending(bw) {
		gracefulswitch.go#L416: 		bw.gsb.mu.Unlock()
		gracefulswitch.go#L419: 	bw.gsb.mu.Unlock()
		gracefulswitch.go#L420: 	bw.gsb.cc.UpdateAddresses(sc, addrs)